//package com.lsc.admin.demo.mq;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.messaging.support.MessageBuilder;
//
///**
// * 消息发送
// *
// * @author ln
// */
//@EnableBinding(MqProSource.class)
//public class MqProducer {
//
//    @Autowired
//    private MqProSource source;
//
//    public void sendMessage(String msg) {
//        try {
//            source.output().send(MessageBuilder.withPayload(msg).build());
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//}